package com.atguigu.gmall.mq.config.component;

import com.rabbitmq.client.Channel;

import java.io.IOException;

/**
 * @Author:lyd
 * @Date:2023/9/5 19:27
 * @Version:1.0
 * @Description
 **/
public interface RabbitService {

    /**
     * 消息发送
     * @param exchange
     * @param rk
     * @param msg
     */
    void sendMsg(String exchange, String rk, Object msg);

    void reTry(String msg, Channel channel, long deliveryTag, int retryCount) throws IOException;
}
